package com.pk.flink.functions.source;

import com.pk.flink.bean.Access;
import org.apache.flink.api.java.functions.KeySelector;

public class AccecssKeyByFunction implements KeySelector<Access,String> {

    @Override
    public String getKey(Access access) throws Exception {
        return access.getDomain();
    }
}
